package org.example.rabbitmq.client.pubsub;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class PubSubTest {
    public static void main(String[] args) throws InterruptedException, TimeoutException, IOException {
        PubSub pubSub = new PubSub();
        pubSub.registerListener("sync");
        pubSub.registerListener("save");
        pubSub.publish(5);
        pubSub.shutdown();
    }
}